package cn.dmp.tags

import org.apache.commons.lang.StringUtils
import org.apache.spark.sql.Row

object Tags4Area extends Tags{
    /**
      * 行数据 -》 标签数据
      *
      * @param args
      * @return
      */
    override def makeTags(args: Any*): Map[String, Int] = {

        var tags = Map[String, Int]()
        val row = args(0).asInstanceOf[Row]

        // 地域
        val pName = row.getAs[String]("provincename")
        val cName = row.getAs[String]("cityname")
        if (StringUtils.isNotEmpty(pName)) tags += "ZP"+pName -> 1
        if (StringUtils.isNotEmpty(cName)) tags += "ZC"+cName -> 1

        tags
    }
}
